//package com.szholly.data.mongodb;
//
//import com.szholly.data.general.IDataReader;
//import com.szholly.data.general.RowBase;
//import com.mongodb.DBCursor;
//import com.mongodb.DBObject;
//
///**
// * 定义monogdb的数据读取对象
// */
//public class DBCursorDataReader<T extends RowBase> implements IDataReader {
//
//	private DBCursor dbCursor;
//	private Class<T> beanClass;
//	private T rowResult;
//
//	public DBCursorDataReader(Class<T> beanClass, DBCursor dbCursor) {
//		this.dbCursor = dbCursor;
//		this.beanClass = beanClass;
//	}
//
//	@SuppressWarnings("unchecked")
//	@Override
//	public T getRow() {
//		return rowResult;
//	}
//
//	@SuppressWarnings("unchecked")
//	@Override
//	public boolean read() {
//		rowResult = null;
//		if (dbCursor.hasNext()) {
//			DBObject row = dbCursor.next();
//			try {
//				rowResult = beanClass.newInstance();
//			} catch (InstantiationException e) {
//				e.printStackTrace();
//			} catch (IllegalAccessException e) {
//				e.printStackTrace();
//			}
//			rowResult.setIsNew(false);
//			rowResult.putAll(row.toMap());
//			return true;
//		} else {
//			return false;
//		}
//	}
//}